# -*-coding:utf-8 -*-
# @功能描述：
# @程序作者：李
import requests
import pymongo


client = pymongo.MongoClient('192.168.37.100',27017) #创建连接

book_weather = client['weather'] #创建名为 "weather" 的数据库

sheet_weather = book_weather['sheet_weather'] #在"weather"数据库中建表"sheet_weather"

url = 'http://cdn.heweather.com/china-city-list.txt'  #国内城市ID

data = requests.get(url)  #获取网页数据

data.encoding = 'utf8' #数据的编码方式为utf8，否则会乱码

data1 = data.text.split("\n") #通过split将文本转换为列表

for i in range(6):   #删除前6行不需要的数据
    data1.remove(data1[0])

for item in data1:
    #接口链接中的key后面的xxx改为自己刚刚注册的key,location后加上城市ID
    url = 'https://free-api.heweather.net/s6/weather/forecast?key=99176dd7ad55456e8916e1d1f0fbe77e&location=' + item[2:13]

    print(item)

    data2 = requests.get(url)

    data2.encoding = 'utf8'

    #time.sleep(1)  #避免访问服务器过于频繁，每次访问等待1s(这里可以不加)

    dic = data2.json()

    sheet_weather.insert_one(dic) #向表中插入数据
